package com.cqk.bigdata.kafka;

import org.apache.kafka.clients.producer.Callback;
import org.apache.kafka.clients.producer.RecordMetadata;

/**
 * @author: cqk
 * @date: 2018/4/2 14:07
 * @param
*/
public class DemoProducerCallback  implements Callback {
    /**
     *
     * @param metadata 记录元数据（分区，偏移量）
     * @param exception 如果kafka返回一个错误，onCompletion会抛出一个非空异常
     */

    public void onCompletion(RecordMetadata metadata, Exception exception) {

        if (exception!=null){
            exception.printStackTrace();
        }
    }
}
